bde2d91cd9d5f1b03f78b162a484b563dcf9a59e,community/kernel/src/test/java/org/neo4j/kernel/impl/store/countStore/InMemoryCountsStoreIntegrationTest.java,InMemoryCountsStoreIntegrationTest,concurrentWorkload,#,91
Before Change
if ( i > 1 && ThreadLocalRandom.current().nextInt( 50 ) == 3 )
{
//THEN
snapshotExecutorService.execute( new SnapshotWorker( i, intermediateStateTestManager, countStore ) );
}
}
workerExecutorService.shutdown();
After Change
ExecutorService executor = Executors.newFixedThreadPool( 10 );
ExecutorCompletionService<Void> ecs = new ExecutorCompletionService<>( executor );
List<Runnable> workers = new ArrayList<>( 10 );
AtomicBoolean stop = new AtomicBoolean();
for ( int i = 0; i < 9; i++ )
{
workers.add( new UpdateWorker( stop, intermediateStateTestManager, countStore ) );
}
workers.add( new SnapshotWorker( 10, stop, intermediateStateTestManager, countStore ) );
//WHEN
for ( Runnable worker : workers )